package com.example.demo.stream.processor;

import com.example.demo.stream.common.DataObject;

public interface RedisStreamMessageHandler<T> {
    void onMessage(DataObject<T> message);
}
